b3ea1a8860a4f7e0163c22a3a9d29110a4b9f9e8,cdap-app-fabric/src/main/java/co/cask/cdap/internal/app/runtime/batch/MapReduceMetricsWriter.java,MapReduceMetricsWriter,reportMapredStats,#,59
Before Change
long mapInputRecords = getTaskCounter(TaskCounter.MAP_INPUT_RECORDS);
long mapOutputRecords = getTaskCounter(TaskCounter.MAP_OUTPUT_RECORDS);
long mapOutputBytes = getTaskCounter(TaskCounter.MAP_OUTPUT_BYTES);
context.getSystemMapperMetrics().gauge(METRIC_COMPLETION, (long) (mapProgress * 100));
context.getSystemMapperMetrics().gauge(METRIC_INPUT_RECORDS, mapInputRecords);
After Change
// emitting to the metrics system.
int mapInputRecords = calcDiffAndSetMapStat(METRIC_INPUT_RECORDS, getTaskCounter(TaskCounter.MAP_INPUT_RECORDS));
int mapOutputRecords = calcDiffAndSetMapStat(METRIC_OUTPUT_RECORDS, getTaskCounter(TaskCounter.MAP_OUTPUT_RECORDS));
int mapOutputBytes = calcDiffAndSetMapStat(METRIC_BYTES, getTaskCounter(TaskCounter.MAP_OUTPUT_BYTES));
context.getSystemMapperMetrics().gauge(METRIC_COMPLETION, (long) (mapProgress * 100));
context.getSystemMapperMetrics().increment(METRIC_INPUT_RECORDS, mapInputRecords);